# 导入pymysql
import pymysql
# 创建数据库类
class Db():
    # 初始化
    def __init__(self):
        self.conm=pymysql.connect(
            host='localhost',
            user='root',
            password='root',
            db='flaskku',
            charset='utf8',# 编码格式
            port=3306, # 端口
            cursorclass=pymysql.cursors.DictCursor # 把元组转换为字典
        )

        # 创建游标
        self.cursor=self.conm.cursor()
    # 添加数据
    def insert(self,sql):
        # 执行sql语句
        self.cursor.execute(sql)
        # 保存
        self.conm.commit()
        return 'insert ok'
    # 删除
    def delete(self,sql):
        self.cursor.execute(sql)
        return 'delete ok'
    # 修改
    def update(self,sql):
        # 执行sql语句
        self.cursor.execute(sql)
        # 保存
        self.conm.commit()
        return 'update ok'
    # 获取一条数据
    def get_one(self,sql):
        self.cursor.execute(sql)
        # 获取一条数据
        res=self.cursor.fetchone()
        return res
    # 获取全部数据
    def get_all(self,sql):
        self.cursor.execute(sql)
        # 获取全部数据
        res=self.cursor.fetchall()
        return res















